var mysql = require("mysql");
//创建连接池
var pool = mysql.createPool({
    host: '127.0.0.1',
    user: 'root',
    password: 'admin',
    database: 's7x'
});

/*
    sql要执行的sql语句
    param是sql语句中?问号的值
    callback回调返回的结果
    1. 从连接池中获取连接(获取失败，则err不为空，获取成功，则连接对象保存在con)
    2. 执行con对象query方法
 */
function zsgc(sql, param) {

    //----------------------------函数调数过程变成异步---------------
    return new Promise((success, fail) => {

        pool.getConnection((err, con) => {
            if (err) {
                fail(err);
            }

            con.query(sql, param, (err, rows) => {
                if (err) {
                    fail(err);
                }


                success(rows);


            });
            //如果没有使用连接池，则关闭连接，如果使用连接池，则把连接放回到连接池
            con.release();


        });
    });

}

module.exports = {zsgc};


